# -*- coding: utf-8 -*-
from airflow.operators.dummy_operator import DummyOperator

from jms.dm.route.dm_route_whole_base_dt.dongbei import dm__dm_route_whole_dongbei_base
from jms.dm.route.dm_route_whole_base_dt.huabei import dm__dm_route_whole_huabei_base
from jms.dm.route.dm_route_whole_base_dt.huadong import dm__dm_route_whole_huadong_base
from jms.dm.route.dm_route_whole_base_dt.huanan import dm__dm_route_whole_huanan_base
from jms.dm.route.dm_route_whole_base_dt.huaxi import dm__dm_route_whole_huaxi_base
from jms.dm.route.dm_route_whole_base_dt.huazhong import dm__dm_route_whole_huazhong_base
from jms.dm.route.dm_route_whole_base_dt.local import dm__dm_route_whole_local_base
from jms.dm.route.dm_route_whole_base_dt.xibei import dm__dm_route_whole_xibei_base
from jms.dm.route.dm_route_whole_base_dt.xinan import dm__dm_route_whole_xinan_base

dm__dm_route_whole_base_dt = DummyOperator(
    task_id='dm__dm_route_whole_base_dt',
    pool='unlimited_pool',
    priority_weight=0,
    email=['zhangqinglin@jtexpress.com','yl_bigdata@yl-scm.com'],
)
dm__dm_route_whole_huaxi_base<<dm__dm_route_whole_xinan_base
dm__dm_route_whole_xinan_base<<dm__dm_route_whole_xibei_base
dm__dm_route_whole_xibei_base<<dm__dm_route_whole_dongbei_base
dm__dm_route_whole_dongbei_base<<dm__dm_route_whole_huazhong_base

dm__dm_route_whole_base_dt << [dm__dm_route_whole_dongbei_base,
                       dm__dm_route_whole_huabei_base,
                       dm__dm_route_whole_huadong_base,
                       dm__dm_route_whole_huanan_base,
                       dm__dm_route_whole_huaxi_base,
                       dm__dm_route_whole_huazhong_base,
                       dm__dm_route_whole_xibei_base,
                       dm__dm_route_whole_xinan_base,
                       dm__dm_route_whole_local_base,
                       ]
